package com.sqllog.core;

/**
 * canal 客户端接口层
 *
 * @author chennengcheng
 * @date 2020-08-24 17:36
 * @remark
 */

public interface CanalClient {

    /**
     * 开启 canal 客户端，并根据配置连接到 canal ,然后进行针对性的监听
     */
    void start(Thread.UncaughtExceptionHandler exceptionHandler);

    /**
     * 关闭 canal 客户端
     */
    void stop();

    /**
     * 获取状态
     * @return
     */
    boolean isRunning();

}
